package dailearn.stream.input;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author daify
 * @date 2019-07-14
 */
public interface GetMessage {

    String NAME = "testMessage";

    /**
     * 设置输入信息绑定的目标
     * @return
     */
    @Input(NAME)
    SubscribableChannel testInPut();

}
